// 创建一个包含10个元素的RDD，将其中所有元素按空格切分成单词，并将所有单词变成小写形式（转换小写toLowerCase）。

import org.apache.spark.{SparkConf, SparkContext}

object RDDExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkConf对象和SparkContext对象
    val conf = new SparkConf().setAppName("RDDExample").setMaster("local")
    val sc = new SparkContext(conf)
    
    // 创建包含10个元素的RDD
    val rdd = sc.parallelize(Seq("Hello World", "How are you", "Spark is awesome", "Scala is amazing", "Big Data"))
    
    // 对RDD进行转换和操作
    val words = rdd.flatMap(_.split(" "))
    val lowercaseWords = words.map(_.toLowerCase)
    
    // 输出结果
    lowercaseWords.foreach(println)
    
    // 关闭SparkContext对象
    sc.stop()
  }
}
